package cn.murky.redismq;

import org.noear.snack.ONode;

/**
 * 使用redis实现mq消息的模板接口
 */
public interface RedisMqTemplate {

    /**
     * 发布消息
     * 一般不需要使用,自己重新实现一个即可
     */
    default void publish(){}

    /**
     * 监听消息,不需要调用,只需要实现即可
     *
     */
    void subscribe();

    /**
     * 获取消息主题
     */
    String getTopic();
}
